9321dc73113ae19615536b93fc33eeb53a9fa88a,spring-cloud-function-task/src/main/java/org/springframework/cloud/function/task/TaskConfiguration.java,TaskConfiguration,commandLineRunner,#FunctionCatalog#,50
Before Change
.lookupSupplier(properties.getSupplier());
String functionName = properties.getFunction();
Function<Flux<Object>, Flux<Object>> function = (functionName.indexOf(',') == -1)
? registry.lookupFunction(functionName)
: registry.composeFunction(
StringUtils.commaDelimitedListToStringArray(functionName));
final Consumer<Object> consumer = registry
.lookupConsumer(properties.getConsumer());
After Change
.lookupSupplier(properties.getSupplier());
String functionName = properties.getFunction();
Function<Flux<Object>, Flux<Object>> function = registry
.lookupFunction(functionName);
final Consumer<Object> consumer = registry
.lookupConsumer(properties.getConsumer());
final CountDownLatch latch = new CountDownLatch(1);